package cn.karent.processor;

/**
 * @author wanshengdao
 * @date 2025/3/20
 */
public interface Processor {

    /**
     * Rocketmq消息处理实现类
     *
     * @param msg 消息体
     */
    void process(String msg);

}
